/*
 * package com.wugui.datax.rpc.registry.impl;
 * 
 * import com.wugui.datax.registry.XxlRegistryClient; import
 * com.wugui.datax.registry.model.XxlRegistryDataParamVO; import
 * com.wugui.datax.rpc.registry.ServiceRegistry;
 * 
 * import java.util.*;
 * 
 */
/**
 * service registry for "xxl-registry v1.0.1"
 *
 * @author xuxueli 2018-11-30
 *//*
	 * 
	 * public class XxlRegistryServiceRegistry extends ServiceRegistry {
	 * 
	 * public static final String XXL_REGISTRY_ADDRESS = "XXL_REGISTRY_ADDRESS";
	 * public static final String ACCESS_TOKEN = "ACCESS_TOKEN"; public static final
	 * String BIZ = "BIZ"; public static final String ENV = "ENV";
	 * 
	 * private XxlRegistryClient xxlRegistryClient;
	 * 
	 * public XxlRegistryClient getXxlRegistryClient() { return xxlRegistryClient; }
	 * 
	 * @Override public void start(Map<String, String> param) { String
	 * xxlRegistryAddress = param.get(XXL_REGISTRY_ADDRESS); String accessToken =
	 * param.get(ACCESS_TOKEN); String biz = param.get(BIZ); String env =
	 * param.get(ENV);
	 * 
	 * // fill biz = (biz != null && biz.trim().length() > 0) ? biz : "default"; env
	 * = (env != null && env.trim().length() > 0) ? env : "default";
	 * 
	 * xxlRegistryClient = new XxlRegistryClient(xxlRegistryAddress, accessToken,
	 * biz, env); }
	 * 
	 * @Override public void stop() { if (xxlRegistryClient != null) {
	 * xxlRegistryClient.stop(); } }
	 * 
	 * @Override public boolean registry(Set<String> keys, String value) { if (keys
	 * == null || keys.size() == 0 || value == null) { return false; }
	 * 
	 * return xxlRegistryClient.registry(buildRegistryData(keys, value)); }
	 * 
	 * @Override public boolean remove(Set<String> keys, String value) { if (keys ==
	 * null || keys.size() == 0 || value == null) { return false; } return
	 * xxlRegistryClient.remove(buildRegistryData(keys, value)); }
	 * 
	 * public List<XxlRegistryDataParamVO> buildRegistryData(Set<String> keys,
	 * String value) { List<XxlRegistryDataParamVO> registryParams = new
	 * ArrayList<>(); for (String key : keys) { registryParams.add(new
	 * XxlRegistryDataParamVO(key, value)); } return registryParams; }
	 * 
	 * 
	 * @Override public Map<String, TreeSet<String>> discovery(Set<String> keys) {
	 * return xxlRegistryClient.discovery(keys); }
	 * 
	 * @Override public TreeSet<String> discovery(String key) { return
	 * xxlRegistryClient.discovery(key); }
	 * 
	 * }
	 */
